package taskrunner

/*
runner 运行常驻任务
startDispatcher： 两个channel
任务一 control channel 任务做完，处理新任务
任务二 data channel 真正的数据channel
*/

const (
	READY_TO_DISPATCH = "d"
	READY_TO_EXECUTE  = "e"
	CLOSE             = "c"
)

// control channel
type ControlChan chan string

// data channel 下发的数据
type DataChan chan interface{}

// 下发任务的函数
type Fn func(dc DataChan) error
